package com.ifp.core.connector;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @Classname AbstractRPCConnector
 * @Description rpc基础类
 * @Date 2019/7/10 22:16
 * @Created by zzh
 *          <p>
 *          zhuzh@belink.com
 *          </p>
 * @Version 1.0
 */
public abstract class AbstractRPCConnector<V> extends AbstractConnector<String, V> {
    /**
     * rpc 订阅者 保持是否初始化状态 已经初始化为true，未初始化为false
     */
    ConcurrentHashMap<String, Boolean> rpcConsumerStateMap = new ConcurrentHashMap<>();

    public Map<String, Boolean> getRpcConsumerStateMap() {
        return rpcConsumerStateMap;
    }

    public void setRpcConsumerStateMap(ConcurrentHashMap<String, Boolean> rpcConsumerStateMap) {
        this.rpcConsumerStateMap = rpcConsumerStateMap;
    }

    String version;

    public String getVersion() {
        return version;
    }

    public void setVersion(String version) {
        this.version = version;
    }
}
